package com.yun.zhong.fu.sharecenter.rocketmq;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * @Author RenPu
 * @Date 2021/1/4 17:26
 * @Version 1.0
 * @Description: 实现自定义接口消息的生产与推送
 **/
public interface MySource {

    String MY_OUTPUT = "my-output";

    @Output("MY_OUTPUT")
    MessageChannel output();


}
